

package com.hazelcast.internal.nearcache.impl.invalidation;

import com.hazelcast.spi.impl.NodeEngine;
import com.hazelcast.spi.impl.eventservice.EventRegistration;

import java.util.function.Predicate;


/**
 * Sends invalidations to Near Caches immediately.
 */
public class NonStopInvalidator extends Invalidator {

    public NonStopInvalidator(String serviceName, Predicate<EventRegistration> eventFilter, NodeEngine nodeEngine) {
        super(serviceName, eventFilter, nodeEngine);
    }

    @Override
    protected void invalidateInternal(Invalidation invalidation, int orderKey) {
        sendImmediately(invalidation, orderKey);
    }
}
